import sqlite3
import  pandas as pd

# sql文件夹路径
sql_path = 'sql' + '\\'
#
# # sql文件名， .sql后缀的
sql_file = 'df_goods_typeinfo.sql'

# 读取 sql 文件文本内容
sql = open(sql_path + sql_file, 'r', encoding='utf8')
sqltxt = sql.readlines()
conn=sqlite3.connect("db.sqlite3")#打开或创建数据库
c=conn.cursor()                 #获取游标

for i in sqltxt:
    print(i.strip())
# 此时 sqltxt 为 list 类型

#读取之后关闭
    sql=i
    c.execute(sql)                  #执行sql语句
    conn.commit()                   #提交数据库操作
conn.close()
print("ok")


# conn=sqlite3.connect("db.sqlite3")#打开或创建数据库
# c=conn.cursor()                 #获取游标
#
#
# # 此时 sqltxt 为 list 类型
#
# # 读取之后关闭
# sql='delete  from df_goods_typeinfo;'
# c.execute(sql)                  #执行sql语句
# print(c.fetchall())
#
# conn.commit()                   #提交数据库操作
# conn.close()
# print("ok")
